package com.athui.bean.task;

import org.apache.flink.connector.file.src.reader.TextLineInputFormat;

/**
 * @description: TODO
 * @autor: zhangzhonghui
 * @create: 2024-08-28 22:01
 * @Version: 1.0
 */
public class FileTask extends SameTask{

    /**
     * @description: TODO 文件路径
     *  可以是文件名全路径，或文件目录全路径
     * @author: 阿辉大人
     * @create: 2024/8/28 22:26
     * @version: 1.0
    **/
    private String filePath;

    /**
     * @description: TODO 文件编码
     * @author: 阿辉大人
     * @create: 2024/8/28 22:27
     * @version: 1.0
    **/
    private String charsetName= TextLineInputFormat.DEFAULT_CHARSET_NAME;


    public FileTask(String filePath){
        this.filePath=filePath;
    }


    public String getFilePath() {
        return filePath;
    }

    public void setFilePath(String filePath) {
        this.filePath = filePath;
    }

    public String getCharsetName() {
        return charsetName;
    }

    public void setCharsetName(String charsetName) {
        this.charsetName = charsetName;
    }

    @Override
    public void setTaskType(int taskType) {
        super.setTaskType(SameTask.FILE_TASK_TYPE);
    }
}
